package com.wyg.epkafkastarter.consumer.impl;

import com.wyg.epkafkastarter.constant.Topic;
import com.wyg.epkafkastarter.consumer.BatchConsumer;
import com.wyg.epkafkastarter.consumer.BatchConsumerBase;
import org.springframework.kafka.listener.ContainerProperties;

/**
 * @Author: WangYongGan
 * @Date: 2022/5/18 0:09
 * @Description:
 */
public class BatchMailerConsumer extends BatchConsumerBase {

    public static void start(BatchConsumer consumer) {
        BatchConsumerBase batchConsumerBase = new BatchConsumerBase();
        final ContainerProperties containerProperties = new ContainerProperties(Topic.EpMail.getValue());
        batchConsumerBase.start(batchConsumerBase, consumer, containerProperties);
    }

}
